package syan.kafkastream.Service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author CHENTAIWEN
 * @create 2022/8/24 15:07
 */
public interface EsChannel {

    String STREAM_DEMO1_INPUT ="demo_1_input";
    String STREAM_DEMO2_INPUT ="demo_2_input";
    String STREAM_DEMO1_OUTPUT ="demo_1_output";
    String STREAM_DEMO2_OUTPUT ="demo_2_output";

    @Input(STREAM_DEMO1_INPUT)
    MessageChannel messageDemo1Input();

    @Input(STREAM_DEMO2_INPUT)
    MessageChannel messageDemo2Input();

    @Output(STREAM_DEMO1_OUTPUT)
    MessageChannel messageDemo1Output();

    @Output(STREAM_DEMO2_OUTPUT)
    MessageChannel messageDemo2Output();
}